﻿using System;

namespace Cngot.Extensions.EventBus.Kafka
{
    public class KafkaProducerOptions
    {

        /// <summary>
        /// 键值
        /// </summary>
        public Func<IServiceProvider, string> DefaultKey { get; set; }


        /// <summary>
        /// 分区，不指定分区即交给kafka指定分区
        /// </summary>
        public int? Partition { get; set; }

        /// <summary>
        /// 保留发布者数
        /// </summary>
        public int InitializeCount { get; set; } = 5;
    }
}
